f76256539518ac44b3a7c327fc471c506f91f9b7,src/org/jgroups/protocols/UFC.java,UFC,handleDownMessage,#Event#Message#number#,86

Before Change


            return down_prot.down(evt);
        }

        if(max_block_times != null) {
            long tmp=getMaxBlockTime(length);
            if(tmp > 0)
                end_time.set(System.currentTimeMillis() + tmp);
        }

        UfcCredit cred=(UfcCredit)sent.get(dest);

After Change


            return down_prot.down(evt);
        }

        long block_time=max_block_times != null? getMaxBlockTime(length) : max_block_time;
        
        while(running) {
            if(cred.decrementIfEnoughCredits(length, 0)) // timeout == 0: don't block